package com.quanyan.place.wrapper;

import com.alibaba.rocketmq.common.message.MessageExt;
import com.quanyan.api.APIResponse;

/**
 * Created by Kingson.chan on 2016/8/16 0016.
 */
public interface MqPlaceConsumerWrapper {

    Integer MQ_PLACE_GROUP_TYPE = 0;
    Integer MQ_PLACE_PUSH_MESSAGE_TYPE = 1;
    Integer MQ_PLACE_UPDATE_INDEX_TYPE = 2;

    /**
     * 消息处理入口
     * @param messageExt
     * @return
     */
    APIResponse placeConsumerOperate(MessageExt messageExt);
}
